from __future__ import absolute_import, unicode_literals
from kombu import Connection


with Connection('amqp://guest@localhost//') as conn:
    simple_queue = conn.SimpleQueue('simple_queue')
    message = simple_queue.get(block=True, timeout=1)
    print("Received:{0}".format(message.payload))
    message.ack()
    simple_queue.close()






